# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.oracle import jms_oracle__dm_cn_departure_transfer_timely_route_day_dt

jms_oracle__dm_cn_departure_transfer_timely_route_wek_dt = BashOperator(
    task_id='jms_oracle__dm_cn_departure_transfer_timely_route_wek_dt',
    execution_timeout=timedelta(hours=1),
    email=['jimmyk.ji@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms/oracle/dm_cn_departure_transfer_timely_route_wek_dt/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

jms_oracle__dm_cn_departure_transfer_timely_route_wek_dt << [jms_oracle__dm_cn_departure_transfer_timely_route_day_dt]